#ifndef _M_ASYNCWORKER_H_
#define _M_ASYNCWORKER_H_

#include "../mqthird/include/muduo/net/EventLoopThread.h"
#include "../mqcommon/threadpool.hpp"

namespace MyRabbitMQ
{
    class AsyncWorker
    {
    public:
        using ptr = std::shared_ptr<AsyncWorker>;

        AsyncWorker(int count_thread = 16)
        :m_pool(count_thread){}

        muduo::net::EventLoopThread m_eventLoopThread; //muduo线程循环 
        threadpool m_pool;  //线程池
    };

};


#endif